package saas.adapter.sdk.core.hook;

import org.apache.rocketmq.client.hook.ConsumeMessageHook;
import saas.adapter.sdk.callback.ConsumeMessageHookCallback;

/**
 * @title: RmqConsumerTenantConversionHookCallback
 * @description:
 * @author: guan.xin
 * @create: 2021-11-25 09:34
 * @since: JDK8
 */
public class RmqConsumerTenantConversionHookCallback implements ConsumeMessageHookCallback {

    @Override
    public ConsumeMessageHook getHookObject() {
        return new RmqConsumerTenantConversionHook();
    }
}
